package com.test.rabbitmq.simple;

public class SimpleMain {

    public static void main(String[] args) {
        Thread tp = new Thread(new Publisher());
        tp.start();
        try {
            System.out.println("--------------------publish thread join.");
            tp.join();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        System.out.println("--------------------send over.");
        // consume start
        Thread tc = new Thread(new Consumer());
        tc.start();
    }
}
